Micron Document
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
| SparkN0de-git | SparkN0de |
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Node / ReticulumProjects / LXMF.git / commits / 2249300


Commit 22493005dc33531d1df0ff93de6dfddb0ebb5144

󰉖 Browse tree at this commit

Parents : 7ecd3c0
Author : Mark Qvist <mark@unsigned.io>
Date : 2024-03-01T23:48:12+01:00

Overhead calculation for propagation transfer limits

Changes

1 files changed, 3 insertions(+), 2 deletions(-)

M LXMF/LXMPeer.py +3 -2

Diff

diff --git a/LXMF/LXMPeer.py b/LXMF/LXMPeer.py
index 5ee8986..b1a49af 100644
--- a/LXMF/LXMPeer.py
+++ b/LXMF/LXMPeer.py
@@ -163,7 +163,8 @@ class LXMPeer:
self.unhandled_messages.pop(transient_id)
unhandled_entries.sort(key=lambda e: e[1], reverse=False)
- cumulative_size = 0
+ per_message_overhead = 16 # Really only 2 bytes, but set a bit higher for now
+ cumulative_size = 24 # Initialised to highest reasonable binary structure overhead
for unhandled_entry in unhandled_entries:
transient_id = unhandled_entry[0]
weight = unhandled_entry[1]
@@ -171,7 +172,7 @@ class LXMPeer:
if self.propagation_transfer_limit != None and cumulative_size + lxm_size > (self.propagation_transfer_limit*1000):
pass
else:
- cumulative_size += lxm_size
+ cumulative_size += (lxm_size+per_message_overhead)
unhandled_ids.append(transient_id)
RNS.log("Sending sync request to peer "+str(self.destination), RNS.LOG_DEBUG)


──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────